import pymysql

#1.建立数据库连接
connect = pymysql.connect(
    # MySQL数据库的IP地址，默认127.0.0.1（代表本地）
    host='127.0.0.1',
    # MySQL数据库的用户名
    user='root',
    # MySQL数据库的密码
    password='123456',
    # MySQL数据库服务的端口号；默认为3306
    port=3306,
    # 数据库名称
    db='spider',
    # 字符编码
    charset='utf8'
)
#2.使用cursor()方法获取操作游标
cursor = connect.cursor()
#3.products表内新增一条数据
#新增数据SQL语句
insertSql = """INSERT INTO products(top_class,
         sec_class, product_name, low_price, avg_price,
         high_price, specs, origin, unit, update_time)
         VALUES ('蔬菜', '水菜', '奶白菜', 2.0, 2.0, 3.0,
         '大', '冀', '斤', '2022-06-07')
         """
try:
   # 执行sql语句
   cursor.execute(insertSql)
   # 提交到数据库执行
   connect.commit()
except:
   # 发生异常，回滚
   connect.rollback()

#4.关闭数据库连接
connect.close()
